//package erperp.cn;
//
//import com.ppdai.infrastructure.mq.biz.dto.base.MessageDto;
//import com.ppdai.infrastructure.mq.biz.dto.base.ProducerDataDto;
//import com.ppdai.infrastructure.mq.biz.event.ISubscriber;
//import com.ppdai.infrastructure.mq.client.MqClient;
//import com.ppdai.infrastructure.mq.client.exception.ContentExceed65535Exception;
//import com.ppdai.infrastructure.mq.client.exception.MqNotInitException;
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//
//import java.util.List;
//
//public class TestSub implements ISubscriber {
//	Logger logger = LoggerFactory.getLogger(TestSub.class);
//	@Override
//	public List<Long> onMessageReceived(List<MessageDto> messages) {
//		try {
//			logger.info("接收到消息: {}",messages.size());
//			MqClient.publish("test2",null, new ProducerDataDto(messages.get(0).getBody()));
//		} catch (MqNotInitException e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		} catch (ContentExceed65535Exception e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		}
//		return null;
//	}
//
//}
